package com.hdaccp.ch02
import org.apache.spark.sql.SparkSession
/**
  * spark 分析 .txt文件
  */
object Demo4 {
  def main(args: Array[String]): Unit = {
    //1.得到sparkSession对象
    val sparkSession = SparkSession.builder().master("local[2]").appName("ch02Demo4App").getOrCreate()

    import sparkSession.implicits._

   // val rdd = sparkSession.sparkContext.textFile("f:/a.txt") ;
   // val dataFrame =  rdd.map(x=>x.split(" ")).map(x=>Hello(x(0),x(1))).toDF() ;


    //
    sparkSession.stop() ;
  }

  case class Hello(a:String,b:String) ;
}
